package cn.kbblog.activemq;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;
import org.springframework.stereotype.Component;


/**
 * 生产者
* @author ykb yang.kb@topcheer.com
* @date 2017年5月27日 上午11:50:44 
*
 */
@Component
public class Producer {
	
	private static final Logger  LOGGER = LoggerFactory.getLogger(Producer.class);
	
//	@Autowired
//    @Qualifier("jmsQueueTemplate")
//    private JmsTemplate jmsTemplate;   

    /**
     * 发送一条消息到指定的队列（目标）
     * @param queueName 队列名称
     * @param message 消息内容
     */
    public void send(final String queueName,final String message){

//    	jmsTemplate.send(queueName, new MessageCreator() {
//			@Override
//			public Message createMessage(Session session) throws JMSException {
//	            LOGGER.debug("{} : send message {}", queueName ,message);
//	            String msg = queueName + " : send message " + message;
//	        	System.out.println(msg);
//				return session.createTextMessage(message);
//			}
//        });

    }
    
}
